//package com.example.order.producer;
//
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.messaging.Source;
//import org.springframework.messaging.MessageChannel;
//import org.springframework.messaging.support.MessageBuilder;
//import org.springframework.stereotype.Component;
//
//@Component
//@EnableBinding(Source.class)
//public class MessageProducer {
//
//    @Autowired
//    private MessageChannel output;
//
//    public void send(){
//        String msessage = "hello stream~~~";
//
//        //发送消息
//        output.send(MessageBuilder.withPayload(msessage).build());
//
//        System.out.println("消息发送成功~~~");
//
//    }
//}
